package com.zy.rpc.consumer.transport;

import com.zy.rpc.common.ask.RpcRequest;
import com.zy.rpc.common.ask.RpcResponse;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;

/**
 * @author zy
 * @date 2023/5/7 16:01
 */
public interface NettyClientTransportFactory {

     CompletableFuture<RpcResponse> sendRecquest(RpcRequest rpcRequest, String address, Integer port) throws InterruptedException, ExecutionException, TimeoutException;


}
